Node / meshtastic / Meshtastic-Android / files / app / src / test / java / com / geeksville / mesh / repository / radio / NordicBleInterfaceDrainTest.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787com.geeksville.mesh.repository.radio

Tff7b72import T7ee787io.mockk.clearMocks

Tff7b72import T7ee787io.mockk.mockk

Tff7b72import T7ee787io.mockk.verify

Tff7b72import T7ee787kotlinx.coroutines.ExperimentalCoroutinesApi

Tff7b72import T7ee787kotlinx.coroutines.delay

Tff7b72import T7ee787kotlinx.coroutines.test.StandardTestDispatcher

Tff7b72import T7ee787kotlinx.coroutines.test.runTest

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.android.CentralManager

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.android.mock.mock

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.ConnectionResult

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.PeripheralSpec

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.PeripheralSpecEventHandler

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.Proximity

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.ReadResponse

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.WriteResponse

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.internal.MockRemoteCharacteristic

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.core.CharacteristicProperty

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.core.LegacyAdvertisingSetParameters

Tff7b72import T7ee787no.nordicsemi.kotlin.ble.core.Permission

Tff7b72import T7ee787org.junit.Ignore

Tff7b72import T7ee787org.junit.Test

Tff7b72import T7ee787java.util.UUID

Tff7b72import T7ee787kotlin.time.Duration.Companion.milliseconds

Tff7b72import T7ee787kotlin.uuid.ExperimentalUuidApi

Tff7b72import T7ee787kotlin.uuid.Uuid

Tf0883e@OptInTb4b4b4(Te6edf3ExperimentalCoroutinesApiTff7b72::Te6edf3classTb4b4b4, Te6edf3ExperimentalUuidApiTff7b72::Te6edf3classTb4b4b4)

Tff7b72class T56d364NordicBleInterfaceDrainTest Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3testDispatcher Tff7b72= Te6edf3StandardTestDispatcherTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff00:11:22:33:44:55Ta5d6ff"

Tff7b72private Tff7b72fun Te6edf3UUIDTb4b4b4.Td2a8fftoKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3Uuid Tff7b72= Te6edf3UuidTb4b4b4.Te6edf3parseTb4b4b4(Tff7b72thisTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)Tb4b4b4)

Tf0883e@IgnoreTb4b4b4(Ta5d6ff"Ta5d6ffFlaky: relies on timing in the Nordic BLE mock library which causes intermittent CI failuresTa5d6ff"Tb4b4b4)

Tf0883e@Test

Tff7b72fun Td2a8ff`drainPacketQueueAndDispatch reads multiple packets until empty`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3centralManager Tff7b72= Te6edf3CentralManagerTb4b4b4.Te6edf3FactoryTb4b4b4.Te6edf3mockTb4b4b4(Te6edf3scope Tff7b72= Te6edf3backgroundScopeTb4b4b4)

Tff7b72val Te6edf3service Tff7b72= Te6edf3mockkTff7b72<Te6edf3RadioInterfaceServiceTff7b72>Tb4b4b4(Te6edf3relaxed Tff7b72= Tff7b72trueTb4b4b4)

Tff7b72var Te6edf3fromRadioHandleTb4b4b4: Tffa657Int Tff7b72= Tff7b72-T79c0ff1

Tff7b72var Te6edf3fromNumHandleTb4b4b4: Tffa657Int Tff7b72= Tff7b72-T79c0ff1

Tff7b72val Te6edf3packetsToRead Tff7b72= Te6edf3mutableListOfTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x01Tb4b4b4)Tb4b4b4, Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x02Tb4b4b4)Tb4b4b4, Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x03Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3eventHandler Tff7b72=

Tff7b72object Tb4b4b4: T56d364PeripheralSpecEventHandler Tb4b4b4{

Tff7b72override Tff7b72fun Td2a8ffonConnectionRequestTb4b4b4(Te6edf3preferredPhyTb4b4b4: Te6edf3ListTff7b72<Te6edf3noTb4b4b4.Te6edf3nordicsemiTb4b4b4.Te6edf3kotlinTb4b4b4.Te6edf3bleTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3PhyTff7b72>Tb4b4b4) Tff7b72=

Te6edf3ConnectionResultTb4b4b4.Te6edf3Accept

Tff7b72override Tff7b72fun Td2a8ffonReadRequestTb4b4b4(Te6edf3characteristicTb4b4b4: Te6edf3MockRemoteCharacteristicTb4b4b4)Tb4b4b4: Te6edf3ReadResponse Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3characteristicTb4b4b4.Te6edf3instanceId Tff7b72=Tff7b72= Te6edf3fromRadioHandleTb4b4b4) Tb4b4b4{

Tff7b72return Tff7b72if Tb4b4b4(Te6edf3packetsToReadTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3p Tff7b72= Te6edf3packetsToReadTb4b4b4.Te6edf3removeAtTb4b4b4(T79c0ff0Tb4b4b4)

Te6edf3printlnTb4b4b4(Ta5d6ff"Ta5d6ffMock: Returning packet Tffd700${Te6edf3pTb4b4b4.Te6edf3contentToStringTb4b4b4(Tb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4)

Te6edf3ReadResponseTb4b4b4.Te6edf3SuccessTb4b4b4(Te6edf3pTb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3printlnTb4b4b4(Ta5d6ff"Ta5d6ffMock: Queue empty, returning emptyTa5d6ff"Tb4b4b4)

Te6edf3ReadResponseTb4b4b4.Te6edf3SuccessTb4b4b4(Te6edf3byteArrayOfTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tff7b72return Te6edf3ReadResponseTb4b4b4.Te6edf3SuccessTb4b4b4(Te6edf3byteArrayOfTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffonWriteRequestTb4b4b4(Te6edf3characteristicTb4b4b4: Te6edf3MockRemoteCharacteristicTb4b4b4, Te6edf3valueTb4b4b4: Te6edf3ByteArrayTb4b4b4) Tff7b72=

Te6edf3WriteResponseTb4b4b4.Te6edf3Success

Tb4b4b4}

Tff7b72val Te6edf3peripheralSpec Tff7b72=

Te6edf3PeripheralSpecTb4b4b4.Te6edf3simulatePeripheralTb4b4b4(Te6edf3identifier Tff7b72= Te6edf3addressTb4b4b4, Te6edf3proximity Tff7b72= Te6edf3ProximityTb4b4b4.Te6edf3IMMEDIATETb4b4b4) Tb4b4b4{

Te6edf3advertisingTb4b4b4(

Te6edf3parameters Tff7b72= Te6edf3LegacyAdvertisingSetParametersTb4b4b4(Te6edf3connectable Tff7b72= Tff7b72trueTb4b4b4, Te6edf3interval Tff7b72= T79c0ff1T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)Tb4b4b4,

Tb4b4b4) Tb4b4b4{

Te6edf3CompleteLocalNameTb4b4b4(Ta5d6ff"Ta5d6ffMeshtastic_DrainTa5d6ff"Tb4b4b4)

Tb4b4b4}

Te6edf3connectableTb4b4b4(

Te6edf3name Tff7b72= Ta5d6ff"Ta5d6ffMeshtastic_DrainTa5d6ff"Tb4b4b4,

Te6edf3isBonded Tff7b72= Tff7b72trueTb4b4b4,

Te6edf3eventHandler Tff7b72= Te6edf3eventHandlerTb4b4b4,

Te6edf3cachedServices Tff7b72= Tb4b4b4{

Te6edf3ServiceTb4b4b4(Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_SERVICE_UUIDTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3CharacteristicTb4b4b4(

Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_TORADIO_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3properties Tff7b72=

Te6edf3setOfTb4b4b4(

Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3WRITETb4b4b4,

Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3WRITE_WITHOUT_RESPONSETb4b4b4,

Tb4b4b4)Tb4b4b4,

Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3WRITETb4b4b4,

Tb4b4b4)

Te6edf3fromNumHandle Tff7b72=

Te6edf3CharacteristicTb4b4b4(

Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_FROMNUM_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3properties Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3NOTIFYTb4b4b4)Tb4b4b4,

Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3READTb4b4b4,

Tb4b4b4)

Te6edf3fromRadioHandle Tff7b72=

Te6edf3CharacteristicTb4b4b4(

Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_FROMRADIO_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3properties Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3READTb4b4b4)Tb4b4b4,

Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3READTb4b4b4,

Tb4b4b4)

Te6edf3CharacteristicTb4b4b4(

Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_LOGRADIO_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3properties Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3NOTIFYTb4b4b4)Tb4b4b4,

Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3READTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Te6edf3centralManagerTb4b4b4.Te6edf3simulatePeripheralsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3peripheralSpecTb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3nordicInterface Tff7b72=

Te6edf3NordicBleInterfaceTb4b4b4(

Te6edf3serviceScope Tff7b72= Tff7b72thisTb4b4b4,

Te6edf3centralManager Tff7b72= Te6edf3centralManagerTb4b4b4,

Te6edf3service Tff7b72= Te6edf3serviceTb4b4b4,

Te6edf3address Tff7b72= Te6edf3addressTb4b4b4,

Tb4b4b4)

T8b949e// Wait for connection

Te6edf3delayTb4b4b4(T79c0ff2T79c0ff0T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)

Te6edf3verifyTb4b4b4(Te6edf3timeout Tff7b72= T79c0ff5T79c0ff0T79c0ff0T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3serviceTb4b4b4.Te6edf3onConnectTb4b4b4(Tb4b4b4) Tb4b4b4}

Te6edf3clearMocksTb4b4b4(Te6edf3serviceTb4b4b4, Te6edf3answers Tff7b72= Tff7b72falseTb4b4b4, Te6edf3recordedCalls Tff7b72= Tff7b72trueTb4b4b4)

T8b949e// Trigger drain

Te6edf3printlnTb4b4b4(Ta5d6ff"Ta5d6ffSimulating FromNum notification...Ta5d6ff"Tb4b4b4)

Te6edf3peripheralSpecTb4b4b4.Te6edf3simulateValueUpdateTb4b4b4(Te6edf3fromNumHandleTb4b4b4, Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x01Tb4b4b4)Tb4b4b4)

T8b949e// Wait for all packets to be processed

Te6edf3delayTb4b4b4(T79c0ff2T79c0ff0T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)

T8b949e// Verify handleFromRadio was called 3 times

Te6edf3verifyTb4b4b4(Te6edf3timeout Tff7b72= T79c0ff2T79c0ff0T79c0ff0T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3serviceTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3p Tff7b72= Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x01Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3verifyTb4b4b4(Te6edf3timeout Tff7b72= T79c0ff2T79c0ff0T79c0ff0T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3serviceTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3p Tff7b72= Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x02Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3verifyTb4b4b4(Te6edf3timeout Tff7b72= T79c0ff2T79c0ff0T79c0ff0T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3serviceTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3p Tff7b72= Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x03Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3assertTb4b4b4(Te6edf3packetsToReadTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffAll packets should have been readTa5d6ff" Tb4b4b4}

Te6edf3nordicInterfaceTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tb4b4b4}